﻿<?php 

	
	$gdt=new gdt();

	$gdt->gd();


	class gdt{

		public function gd(){


			$input=file_get_contents("php://input");

			//$input=file_get_contents('phone.json');

			$date=json_decode($input,true);

			$key=array_keys($date);

			$value=array_values($date);

			$keystr="(".implode($key, ",").")";

			$valuestr="('".implode($value, "','")."')";

			$query="insert into gdtphone ".$keystr." value ".$valuestr;

			$result=self::insertDb($query);

			if($result['result']){

				$CusName=$date['leads_name'];
				$CusPhone=$date['leads_tel'];
				$ChannelID='1284016882717954048';
				$CusAddress=$date['address'];
				$Remark='';
				self::api($CusName,$CusPhone,$ChannelID,$CusAddress,$Remark);

			}else{

				file_put_contents('phone.json',"电话：".$date['leads_tel']."ID：".$date['leads_id']."erro:".$result['erro']."时间：".date("Y-m-d H:i:s").PHP_EOL,FILE_APPEND);
			}

			echo 'hello qm';
		}

		public function insertDb($query){


	        $host='localhost';
	        $user='root';
	        $password='root';
	        $database='weizandata';
	        $link=mysqli_connect($host, $user, $password, $database);
	        $link->query("set names utf8");
	        $result=mysqli_query($link, $query);
	        //@$arr=mysqli_fetch_all($result, 1);

	        //echo mysqli_error($link);

	        return ["result"=>$result,"row"=>mysqli_affected_rows($link),'erro'=>mysqli_error($link)];
		}
	    public function api($CusName,$CusPhone,$ChannelID,$CusAddress,$Remark)
   		{


	        $data["CusName"]= $CusName;
	        $data["CusPhone"]=$CusPhone;
	        $data["ChannelID"]= $ChannelID;
	        $data["CusAddress"]= $CusAddress;
	        $data["Remark"]=$Remark;
	        $data = json_encode($data);
	        $pp["Service"] = "com.QM.CallCenter.CommonChannelAPI";
	        $pp["Param"] = addslashes($data);

	        $pp = json_encode($pp);
	        $pp = str_replace('\\\\\\',"\\",$pp);

	        $out = self::do_curl("https://capi.qumei.com/api/home/call",$pp,false,"POST");
	        $out = json_decode($out,true);

	        if ($out['statusCode']==200){

	            return 1;

	        }else{

	            return 2;

	        }


   		}
	    public function do_curl($url, $params = array(), $upload = false, $type = 'POST')
	    {

	        $method = strtoupper($type);
	        if ($method == 'GET') {
	            $url = "{$url}?" . http_build_query($params);
	        }
	        $ch = curl_init();
	        //curl_setopt($ch, CURLINFO_HEADER_OUT, true);
	        //输出主机头
	        // com.wx.crmapi.PushCustomerData
	        if ($url=="https://capi.qumei.com/api/home/call"){
	            //定义请求类型
	            $username="webuser";
	            $password="Qumei1993";
	            $timestamp=time();

	            $sign = md5($username.",".$password.",".$timestamp);

	            $token = file_get_contents("token.txt");

	            $headers = array(
	                "Content-Type: application/json",
	                "Authorization: Bearer $token",
	                "username: $username",
	                "password: $password",
	                "timestamp: $timestamp",
	                "sign: $sign"
	            );

	            curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
	        }

	        curl_setopt($ch, CURLOPT_URL, $url);
	        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
	        //curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);
	        // 是否检测服务器的证书是否由正规浏览器认证过的授权CA颁发的
	        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
	        // 是否检测服务器的域名与证书上的是否一致
	        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);

	        if ($method == 'POST') {
	            if ($upload) {        //设置上传文件
	                $file = new \CURLFile($upload['tmp_name'], $upload['type'], $upload['name']);
	                $params[$upload['get_name']] = $file;
	            }
	            //$params = '{"Service":"com.QM.CallCenter.CommonChannelAPI","Param":{\"CusName\":\"test591\u5ba2\u8d44\uff08\u8bf7\u5ffd\u7565\uff09\",\"CusPhone\":\"15107984564\",\"ChannelID\":\"1262592253055078400\",\"CusAddress\":\"\u5317\u4eac\",\"Remark\":\"\"}}';
	            @curl_setopt($ch, CURLOPT_POST, 1);
	            @curl_setopt($ch, CURLOPT_POSTFIELDS, $params);
	        }

	        $result = curl_exec($ch);
	        //$request_header = curl_getinfo( $ch, CURLINFO_HEADER_OUT);
	        //print_r($request_header);
	        //打印发送头信息

	        curl_close($ch);
	        if ($result === null || $result === false) {

	            $this->error('操作出错！');

	        } else {

	            return $result;

	        }

	    }

	}






 ?>